package com.cms.pms;

/**
 * 数据收集器，对存储在store中的Transaction记录进行处理，由Processor定时调用
 * @author zhoushuang
 *
 */
public interface Aggregator {
	/**
	 * 进行数据处理前的准备工作
	 */
	void prepare();
	
	/**
	 * 处理Store中的Transaction记录
	 * @param obj	Transaction对象
	 */
	void handle(Object obj);
	
	/**
	 * 对数据进行归集处理，并将结果写入日志或数据库中
	 */
	void aggregate();
	
}
